#hive数据库
export hive_db=$1
#数据库连接信息
export database_url=$2
export username=$3
export password=$4
# 要导入的表
export table=$5
#转换成大写的表名，对应到数据库中的大小表名。
export upperTable=$(echo $5 | tr '[a-z]' '[A-Z]')

# 要导入的表的日期分区参数
export ds_date=$6

count=`hive -e "select 1 from ${hive_db}.${table} where ds='${ds_date}' limit 1"`

echo "count："${count}
if [ "${count}" == "1" ] ; then
   #清空oracle中数据
   sqoop eval --connect $database_url --username $username --password $password --query "DELETE FROM ${upperTable}"
   #导入hive中的数据到db中
   sqoop export --connect $database_url --username $username --password $password --table $upperTable  --export-dir /apps/hive/warehouse/$hive_db.db/$table/ds=$ds_date --fields-terminated-by '\t'  --input-null-string '\\\\N' --input-null-non-string '\\\\N'
else
   echo "【${ds_date}】没有数据,不执行导入程序"
fi
